package com.duobaoyu.dby.supply.biz.service.queue.service;

import com.duobaoyu.dby.supply.biz.service.queue.core.DistributionQueueMessage;

/**
 * Created by shuming on 2023/9/27 15:51
 */
public abstract class AbstractDistributionQueueJobConsumer {

	/**
	 * 队列名称
	 *
	 * @return
	 */
	public abstract String topicName();

	/**
	 * 消费队列任务
	 *
	 * @param distributionQueueMessage
	 */
	public abstract void consume(DistributionQueueMessage distributionQueueMessage);
}
